# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.dwd_centersend_timerate_detail_dt import jms_dwd__dwd_centersend_timerate_detail_dt
from jms.dwd.oms.dwd_oms_waybill_dt import jms_dwd__dwd_oms_waybill_dt

oss__dm_centersend_timerate_detail_dt = BashOperator(
    task_id='oss__dm_centersend_timerate_detail_dt',
    email=['wangmenglei@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/dm_centersend_timerate_detail_dt/execute.sh',
    execution_timeout=timedelta(minutes=50)
)

oss__dm_centersend_timerate_detail_dt << [
    jms_dwd__dwd_centersend_timerate_detail_dt,
    jms_dwd__dwd_oms_waybill_dt
]
